welo git mirrors - /page/commit.mu

Micron Document

welo git mirrors

Node / public / rns-proxy / commits / eb4d19b

Commit eb4d19b4e7af0e77d9b968ab7369a6a7e7e40bcd

🗀 Browse tree at this commit

Parents : 05c8d56

Author : welo | main nixos computer <empty@empty.com>

Date : 2026-07-06T23:43:24+01:00

one more

Changes

2 files changed, 6 insertions(+), 1 deletions(-)

M src/forwarding.rs +3 -1

M src/relay.rs +3

Diff

diff --git a/src/forwarding.rs b/src/forwarding.rs

index 58a5a95..c8b9f2d 100644

--- a/src/forwarding.rs

+++ b/src/forwarding.rs

@@ -67,7 +67,7 @@ pub async fn tcp_tunnel(mux: MuxHandle, reconnect_notify: Arc<Notify> , port: Fo

loop {

tokio::select! {

accept_result = listener.accept() => {

- let (stream, _addr) = match accept_result {

+ let (stream, addr) = match accept_result {

Ok(sa) => sa,

Err(e) => {

continue;

@@ -82,6 +82,8 @@ pub async fn tcp_tunnel(mux: MuxHandle, reconnect_notify: Arc<Notify> , port: Fo

let session_rx = mux.register_session(sid);

let mux_clone = mux.clone();

+ println!("{:?} {:?}", sid, addr);

tokio::spawn(async move {

relay_forwarded_tcp(sid, stream, mux_clone, session_rx).await;

});

diff --git a/src/relay.rs b/src/relay.rs

index 3550237..a312736 100644

--- a/src/relay.rs

+++ b/src/relay.rs

@@ -49,6 +49,7 @@ pub async fn relay_bidirectional_tcp(

while let Some(frame) = session_rx.recv().await {

match frame.frame_type {

FrameType::Data => {

+ println!("{:?}", &frame.payload);

if let Err(e) = tcp_write.write_all(&frame.payload).await {

warn!("[{}] TCP write error: {}", sid, e);

break;

@@ -284,6 +285,7 @@ pub async fn relay_forwarded_tcp(

match tcp_read.read(&mut buf).await {

Ok(0) => break,

Ok(n) => {

+ println!("{:?} {:?}", sid, &buf[..n]);

mux_fwd.send(FrameType::Data, sid, buf[..n].to_vec());

}